<?php

require_once 'vendor/autoload.php';

use Pheanstalk\Pheanstalk;

/**
 * 连接服务
 * 参数一: 服务器地址
 * 参数二: 端口号, 默认 11300
 */
$pheanstalk = new Pheanstalk('127.0.0.1', 11300);

$arr = array([
        'name' => 'master',
        'age' => 30
    ]);
$arrJson = json_encode($arr);

/**
 * useTube
 * 参数: 管道名
 * 功能: 选择管道, 如果管道不存在则创建
 *
 * put
 * 参数一: 任务内容(string)
 * 参数二(可选): 任务优先级, 默认1024, 取值范围 0-1024 值越小, 优先级越高(int)
 * 参数三(可选): 任务延迟时间, 默认为 60, 单位: 秒
 * 功能: 生产任务
 * 返回值: 任务 id (int)
 */
$jobId = $pheanstalk->useTube('users')->put($arrJson);
// 查看任务列表
$listTubes =  $pheanstalk->listTubes();
print_r($listTubes);

/**
 * statsJob
 * 参数: 任务 id (int)
 * 功能: 查看任务状态
 * 返回值: 数组
 */
$statsJob = $pheanstalk->statsJob($jobId);
print_r($statsJob);
